package com.hscy.push.listenner;

import com.corundumstudio.socketio.AckRequest;
import com.corundumstudio.socketio.SocketIOClient;
import com.corundumstudio.socketio.annotation.OnEvent;
import org.springframework.stereotype.Component;

/**
 * @author xuteng
 * @date 2019/11/6 15:59
 */
@Component
public class EventListenner {

    //消息接收入口，当接收到消息后，查找发送目标客户端，并且向该客户端发送消息，且给自己发送消息
    // 暂未使用
    @OnEvent("messageevent")
    public void onEvent(SocketIOClient client, String message, AckRequest request) {

        System.out.println("收到推送消息：" + message);

        // 做一些其他操作...

        // 发送确认回调给客户端
        request.sendAckData("推送已收到");
    }
}
